2c16d4de73836decbf50acf749588f6c50fb1736,aggregate-snapshot/aggregate-snapshot-service/src/test/java/uk/gov/justice/services/core/aggregate/SnapshotAwareAggregateServiceIT.java,SnapshotAwareAggregateServiceIT,createEventStreamAndApply,#number#String#T#,420

Before Change


    private <T extends Aggregate> Stream<JsonEnvelope> createEventStreamAndApply(long count, String eventName, T aggregate) {
        List<Object> envelopes = new LinkedList<>();
        for (int i = 1; i <= count; i++) {
            JsonEnvelope envelope = envelope().with(metadataWithRandomUUID(eventName).withStreamId(STREAM_ID)).withPayloadOf("value", "name").build();
            aggregate.apply(new EventA(String.valueOf(i)));
            envelopes.add(envelope);
        }

After Change



            JsonEnvelope envelope =
                    envelope()
                    .with(metadataWithRandomUUID(eventName)
                            .createdAt(clock.now())
                            .withStreamId(STREAM_ID))
                    .withPayloadOf("value", "name")
                    .build();